/*
 * 文件名：RealStreamCount.java
 * 版权：亚信联创版权所有
 * 描述：TODO
 * 修改人：yuanze
 * 修改时间：2014年11月24日
 * 修改内容：TODO
 */
package com.ailk.bigdata.etl.realstream.server.model;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
 * @description 实时流计数器
 * @author [yuanze]
 * @version [版本号,2014年11月24日]
 * @see [相关类/方法]
 * @since [产品/模块版本]
 */
public class RealStreamCount
{
	private static Logger logger = LoggerFactory.getLogger(RealStreamCount.class);
	private static long count = 0;// 计数值

	/**
	 * 
	 * @description 计数器增加
	 */
	public static void add()
	{
		try
		{
			// lock.lock();
			count++;
		}
		finally
		{
			// lock.unlock();
		}
	}

	/**
	 * 
	 * @description 重置计数器
	 */
	public static void reset()
	{
		// try
		// {
		// lock.lock();
		// 写到本地文件上
		// File file = new File("count.txt");
		// file.createNewFile();
		// FileUtil.writeStringToFile(file,
		// DateUtil.getTimeStamp() + "计数器个数[" +
		// StreamDataAcceptHandler.count + "]" +
		// System.getProperty("line.separator"), true);
		// logger.warn("package:" + StreamDataAcceptHandler.count);
		// count = 0;
		// }
		// catch (IOException e)
		// {
		// logger.error("读写文件[count.txt]异常", e);
		// }
		// finally
		// {
		// lock.unlock();
		// }
	}

	public static long getCount()
	{
		return count;
	}

	public static void setCount(long count)
	{
		RealStreamCount.count = count;
	}

}
